#pragma once
#include<iostream>
#include<mysql/mysql.h>
#include<memory>
#include<sstream>
#include<vector>
#include<fstream>
#include"logger.hpp"
#include"jsoncpp/json/json.h"
class mysql_util
{
public:
    //需要ip地址、用户名、密码、访问哪个数据库，端口（mysql默认端口3306，如果你写零他也默认使用3306）
    static MYSQL* mysql_create(const std::string &host, const std::string &usrname,const std::string&password,
    const std::string& dbname,uint16_t port=3306)
    {
    //1.初始化句柄
    MYSQL *mysql =mysql_init(NULL);
    if(mysql==NULL){        
        ELOG("mysql init failed");
        return NULL;
    }
    //2.连接服务器
    if(mysql_real_connect(mysql,host.c_str(),usrname.c_str(),password.c_str(),dbname.c_str(),port,NULL,0)==NULL)
    {
        ELOG("connect mysql server failed : %s", mysql_error(mysql));
        mysql_close(mysql);//把句柄关闭释放掉
        return NULL;
    }
    //3.初始化字符集
    if(mysql_set_character_set(mysql,"utf8")!=0)
    {
        ELOG("set client character failed : %s\n", mysql_error(mysql));
        mysql_close(mysql);
        return NULL;
    }
    return mysql;//返回句柄
    }
    //执行需要，句柄和sql语句
    static bool mysql_exec(MYSQL* mysql,const std::string& sql)
    {
        int ret=mysql_query(mysql,sql.c_str());
        if(ret!=0)
        {
            ELOG("%s\n", sql.c_str());
            ELOG("mysql query failed : %s\n", mysql_error(mysql));
            // mysql_close(mysql);//这里不要释放了，不然如果失败的话，这里释放一次，实例化对象析构的时候也会释放一次，就释放两次了
            return false;
        }
        return true;
    }
    //释放
    static void mysql_destroy(MYSQL* mysql)
    {   if(mysql!=NULL)
            mysql_close(mysql);
    } 

};


class json_util
{
public:
    static bool serialize(const Json::Value &root,std::string& str)
    {
       Json::StreamWriterBuilder swb;
       std::unique_ptr<Json::StreamWriter>sw(swb.newStreamWriter());
       std::stringstream ss;
       int ret =sw->write(root,&ss);
       if(ret!=0){
        ELOG("json serialize failed");
        return false;
       }
       str=ss.str();
       return true;
    }
    static bool deserialize(Json::Value &root,std::string& str)
    {
        Json::CharReaderBuilder crb;
        std::unique_ptr<Json::CharReader> cr(crb.newCharReader());
        std::string err;
        bool ret = cr->parse(str.c_str(),str.c_str()+str.size(),&root,&err);
        if(ret==false)
        {
            ELOG("json deserialize,failed:%s",err.c_str());
            return false;
        }
        return true;
    }


};

class string_util
{
public:
    static int split(const std::string &src,const std::string &sep,
    std::vector<std::string> &res)
    {
        size_t pos_record=0;
        while(pos_record<src.size())
        {   
            size_t pos =src.find(sep,pos_record);
            if(pos==std::string::npos)
            {
                res.push_back(src.substr(pos_record));
                break;
            }
            if(pos==pos_record)
            {
                pos_record+=sep.size();
                continue;
            }
            res.push_back(src.substr(pos_record,pos-pos_record));
            pos_record=pos+sep.size();

        }
        return res.size();
    }

};
class file_util
{
public:
    static bool read(const std::string &filename,std::string& body)
    {
        //1.打开文件
        std::ifstream ifs(filename,std::ios::binary);//因为我们打开的文件有可能是文本，也有可能是其他类型的，包含特殊字符 
        //需要对文件的原数据进行操作
        if(ifs.is_open()==false)
        {
            ELOG("%s file open failed",filename.c_str());
            return false;
        }
        //2.获取文件大小----先把文件的读写位置移动到文件末尾，然后再获取此时位置相对于起始位置的偏移量
        size_t fsize=0;
        ifs.seekg(0,std::ios::end);
        fsize=ifs.tellg();
        ifs.seekg(0,std::ios::beg);
        body.resize(fsize);
        //3.将文件所有数据读取出来
        ifs.read(&body[0],fsize);//不能用body.c_str()，因为这个返回的是const的字符串首地址，不能被修改
        if(ifs.good()==false)
        {
            ELOG("read %s file content failed",filename.c_str());
            ifs.close();
            return false;
        }
        //4.关闭文件
        ifs.close();
        return true;


    }
};